package cn.liuwenlin.mq.activemqspringboot.service;

import javax.jms.JMSException;

/**
 * @author 276834
 */
public interface MessagePublishService {

    /**
     * 向activemq队列发送消息
     * @param destination
     * @param msg
     * @throws JMSException
     */
    void send(String destination,String msg) throws JMSException;

    /**
     * 向activemq队列发送消息
     * @param destination
     * @param msg
     * @throws JMSException
     */
    void sendToQueue(String destination,String msg) throws JMSException;

    /**
     * 向activemq队列发送消息
     * @param destination
     * @param msg
     * @throws JMSException
     */
    void sendTopic(String destination, String msg) throws JMSException;
}
